# import json
#
# from celery.app import shared_task
#
# from task.task_running import task_run
#
#
# @shared_task
# def my_celery_task(task_info):
#     task_run(task_info)
#
#
# def push_task_to_celery(task_info):
#     # 这里只是调用Celery任务，它会将任务推送到队列中
#     print(task_info)
#     print("====push_task_to_celery=====")
#     my_celery_task.delay(task_info)
